package com.chatim.nonamechatim.netty.handler;

import com.alibaba.fastjson2.JSON;
import com.chatim.nonamechatim.common.Res;
import com.chatim.nonamechatim.netty.common.Command;
import com.chatim.nonamechatim.netty.common.WSRes;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import lombok.extern.slf4j.Slf4j;

import static com.chatim.nonamechatim.netty.ServerBoot.CHANNELUSER;
import static com.chatim.nonamechatim.netty.ServerBoot.USERLIST;

@Slf4j
public class ConnectionHandler {

    public static void execute(ChannelHandlerContext ctx, Command command) {

        // 判断用户是否已经上线
//        if(USERLIST.containsKey(command.getName())){
//            ctx.channel().writeAndFlush(WSRes.fail("当前用户已经上线"));
//            ctx.channel().disconnect();
//            return;
//        }

        log.info("当前登录用户:{}", command.getFid());
        // 记录连接上来的用户
        USERLIST.put(command.getFid(), ctx.channel());
        CHANNELUSER.put(ctx.channel().id(), command.getFid());
        // 返回信息给客户端
        ctx.channel().writeAndFlush(WSRes.success("与服务器连接建立成功"));
    }
}
